from celery import Celery
import os
#准备
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "meiduo_mall.settings")
# 创建celery实例
app = Celery('celery_tasks')
# 配置broker
app.config_from_object('celery_tasks.config')
# 生产者 任务 函数 定义一个发短信的函数 用celery的实例task装饰器装饰
# 让celery自动检测指定包的任务
app.autodiscover_tasks(['celery_tasks.sms','celery_tasks.email'])

# 消费者




